package com.gitee.kinbug.sniper.web.websocket.msg;

import java.util.concurrent.ConcurrentHashMap;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import com.gitee.kinbug.sniper.web.websocket.entity.WebSocketSender;
import lombok.extern.slf4j.Slf4j;

@Slf4j
@Component
public class SymbolMsg {

	@Autowired
	private ConcurrentHashMap<String, WebSocketSender> senderMap;

	public void msgReceive(String obj) {
		try {
			log.info("---消息接收器：WS收到请求：{},{}", obj, senderMap.size());
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}
